package com.sanfu.etl.service;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.springframework.stereotype.Service;

import java.util.ArrayList;

// *********************
// ** @Date: 2021-06-11
// ** @Author: Camemax
// ** @Description:  ①定义Kafka作为Flink数据流源[输入]的方法 ②Kafka作为Flink数据流源[输出]的方法
// *********************
public interface FlinkKafkaService
{
    ArrayList<DataStream<String>> loadDataStreams(); // 返回多个数据流对象

    DataStream<String> outDataStream();
}
